package io.openmessaging.storage;

import io.openmessaging.Message;
import io.openmessaging.Topic;

import java.nio.ByteBuffer;

/**
 * @author cuijd    2021/9/26 8:56
 */
public interface Storage {
    void save(Message m);

    ByteBuffer get(Topic topic, int queueId, long offset);
}
